package com.chinamobile.websocket.websocketdispatcher.distributor;

import com.chinamobile.websocket.domain.dto.MessageDto;

/**
 * @className: MessageDistributor
 * @description 消息分发器接口
 * @author: fanzhijun
 * @date: 2024/1/22
 **/

public interface MessageDistributor<T extends MessageDto> {

    /**
     * 消息生产
     */
    void distribute(T messageDto);

    /**
     * 消息消费
     */
    void doSend(T messageDto);

}
